package com.biz.primus.ms.search.stream;

import com.biz.primus.search.stream.ProductSearchIndexChannel;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author jiangnan
 * @Description:
 */
public interface ProductIndexSink extends ProductSearchIndexChannel {

    /**
     * 全量索引 input
     * @return
     */
    @Input(PRODUCT_INDEX_ALL)
    SubscribableChannel indexAllInput();

    /**
     * 增量索引 input
     */
    @Input(PRODUCT_INDEX_INCR)
    SubscribableChannel indexIncrInput();

}
